package com.dianshang.rabbitmq;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

/**
 * 消息消费者
 *
 * 订阅与发布模式：
 *      分列模式 Fanout
 */
public class Consumer2 implements MessageListener {

    @Override
    public void onMessage(Message message) {
        byte[] messageBody = message.getBody();
        String msg = new String(messageBody);
        System.out.println("接受到的消息内容2："+msg);
    }

}